--[[ 编码: WMS-100-03 名称: PLC-PLCStateChange 作者：HAN 入口函数： PLCStateChange 功能说明: 新兴项目中的线体PLC状态发生变化后会通过这个可编程接口告诉WMS系统 发送过来的数据是一个Json包，格式如下： {"device_code":"D001","comm_code":"1001_STUS","value":[1,1,0,1008,0,0,0,100],"time":"2023-09-05 16:16:00"} 分别表示下面这些状态 （1） 线体状态 0 空闲 1 运行 2 急停 state （2） 光电信号 0 无框 1 有框 with_tray 有托盘 （3） 任务号 0~65535 task_no （4） 目标地址 1008 线体编号 target_addr （5） 线体信号 0 无动作 1=允许出框 2=允许进框 signal （6） 任务状态反馈 0 无任务 1=出框完成 2=进框完成 task_state （7） 外形检测 目前没有用 （8） 重量 目前没有用 变更记录: --]] wms_dev = require( "wms_devcomm" ) wms_eq = require( "wms_equipment" ) wms_cntr= require( "wms_container" ) wms_wh = require( "wms_wh" ) -- 创建入库作业 -- location 货位 cntr_code 容器编码 -- device_code 输送线线体设备编码 local function create_warehousing_operation( strLuaDEID, device_code, str_loc_code, cntr_code ) local location local nRet -- 判断一下是否已经存在托盘号 = cntr_code 的未完成作业，如果已经存在不需要继续创建作业 -- 因为 PLC 这边有 60s 强制通知策略，因此加一个防护 nRet, strRetInfo = wms_cntr.InOperation( strLuaDEID, cntr_code ) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "WMS_Container_InOperation失败! " .. strRetInfo) end if (strRetInfo == 'yes') then return end -- 获取货位信息 nRet, location = wms_wh.Location_GetInfo( strLuaDEID, str_loc_code ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), 'wms_wh.Location_GetInfo 失败!'..location ) end -- 创建作业 local operation = m3.AllocObject(strLuaDEID,"Operation") operation.start_wh_code = location.wh_code operation.start_area_code = location.area_code operation.start_loc_code = location.code operation.op_type = wms_base.Get_nConst(strLuaDEID, "作业类型-入库") operation.op_def_name = "成品入库" operation.cntr_code = cntr_code operation.ext_data = device_code -- 注意：把线体的编码保存在扩展属性中，在生成任务的时候会用到 nRet, strRetInfo = m3.CreateDataObj( strLuaDEID, operation ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), '创建【作业】失败!'..strRetInfo ) end end -- 创建设备动作队列 -- device_code -- 输送线设备号 task_code -- 任务号 action_code -- 动作码 action -- 动作 line_seg_code -- 线体段号 local function Create_MQAction( strLuaDEID, device_code, task_code, action_code, action, line_seg_code ) if ( device_code == nil or device_code == '' ) then lua.Error( strLuaDEID, debug.getinfo(1), '创建【设备动作队列】失败! 设备号必须有值' ) end -- step2 获取车辆基本信息 local eq nRet, eq = wms_eq.Equipment_GetInfo( strLuaDEID, device_code ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), eq ) end -- 如果车辆没定义工厂标识返回错误 if ( eq.factory == '') then strErr = "设备编号='"..strForkliftNo.."' 没定义工厂标识!" lua.Error( strLuaDEID, debug.getinfo(1), strErr ) end -- step3 判断当前车辆的动作码是否已经在队列中（MQ_EQAction） local mq_eq_action = m3.AllocObject(strLuaDEID,"MQ_EQAction") mq_eq_action.task_code = task_code mq_eq_action.eq_code = device_code mq_eq_action.action_code = action_code mq_eq_action.action = action mq_eq_action.data = line_seg_code -- 线体这里已经存在设备动作记录就不需要继续进行处理 local strCondition = "N_ACTION_CODE = "..action_code.." AND S_EQ_CODE = '"..mq_eq_action.eq_code.."' AND ( N_B_STATE = 0 OR N_B_STATE = 1 ) " strCondition = strCondition.." AND S_DATA = '"..line_seg_code.."'" nRet, strRetInfo = mobox.existThisData( strLuaDEID, "MQ_EQAction", strCondition ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end -- 如果该车辆编码的动作已经在队列，返回，不做处理 if ( strRetInfo == "yes" ) then return end -- step4 把车辆动作写入队列 mq_eq_action.factory = eq.factory mq_eq_action.eq_type = eq.type mq_eq_action.eq_type_name = eq.name nRet, strRetInfo = m3.CreateDataObj( strLuaDEID, mq_eq_action ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end end -- 主函数 -- PLC 状态变化后脚本处理程序 function PLCStateChange ( strLuaDEID ) local nRet, strRetInfo local input_datajson = {} -- step1 获取接口中的Data nRet, input_datajson = m3.GetSysDataJson( strLuaDEID ) if ( nRet ~=0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "PLCStateChange 无法获取数据包!"..input_datajson ) end local device_code = lua.Get_StrAttrValue( input_datajson.device_code ) local comm_code = lua.Get_StrAttrValue( input_datajson.comm_code ) local value = input_datajson.value -- step2： 如果线体无框就返回 if ( value[wms_base.Get_nConst(strLuaDEID,"输送线-光电信号")] ~= 1 ) then return end -- step3 检查从PLC传入的数据进行合法性判断 if ( device_code ~= "S7_Line_01") then lua.Warning( strLuaDEID, debug.getinfo(1), "PLC传入的设备号 device_code 不正确，目前只是接收 S7_Line_01 设备的信号接入!" ) return end if ( comm_code == '' ) then lua.Warning( strLuaDEID, debug.getinfo(1), "PLC传入的设备通讯项编码不能为空!" ) return end if ( value == nil ) then lua.Warning( strLuaDEID, debug.getinfo(1), "PLC传入的设备状态值为 nil! " ) return end lua.Debug( strLuaDEID, debug.getinfo(1), "PLC", input_datajson ) -- 获取线体编码 line_seg_code -- comm_code 的格式是 1001_XXXX 前面是线体编码 local seg = {} local nCount seg = lua.split( comm_code, '_' ) nCount = #seg if ( nCount ~= 2 ) then lua.Warning( strLuaDEID, debug.getinfo(1), "PLC传入的设备通讯项编码格式不正确! "..comm_code ) return end local line_seg_code = seg[1] -- 线体编码 -- step4: 通过OIDeviceCommS请求获取设备目前的托盘号 cntr_code local cntr_code = wms_dev.ReadS7PLCCommsData( strLuaDEID, device_code, line_seg_code.."_CNTR" ) lua.Debug( strLuaDEID, debug.getinfo(1), "cntr_code", cntr_code ) if ( type(cntr_code) ~= "string" ) then lua.Error( strLuaDEID, debug.getinfo(1), "调用OIDeviceCommS接口ReadData返回的容器编码格式不对,必须是字符串类型!" ) end -- step5: 解析返回的容器号，并且进行容器号合格判断 (容器编码TP1/TP2 开头后面7位数字) local strHeader -- 容器号的前3位字符串 nRet, strHeader = XX_CheckCNTRCode( cntr_code ) if ( nRet ~= 0 ) then -- 输出 LED 错误信息 这块代码还需要完善 -- ??? lua.Error( strLuaDEID, debug.getinfo(1), strHeader ) end -- step6: 判断容器是否存在? 不存在创建 if ( wms_cntr.Exist( strLuaDEID, cntr_code ) == false ) then -- 【容器】不存在要先创建【容器】 local container = m3.AllocObject(strLuaDEID,"Container") container.code = cntr_code nRet, strRetInfo = m3.CreateDataObj(strLuaDEID, container) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), '创建【容器】对象失败!'..strRetInfo ) end end -- step7: 通过信号源所在的线体编号确定是 线体目前是做开始入库还是开始出库，或是开始入库到线体目标位置? -- 根据 设备编号 + 通讯项目编码 获取货位号 及 货位的出入口属性 local dev_comms_ext nRet, dev_comms_ext = wms_dev.GetDeviceCommSExtInfo ( device_code, comm_code ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), dev_comms_ext ) end local pos_type = lua.Get_StrAttrValue( dev_comms_ext.pos_type ) local str_loc_code = lua.Get_StrAttrValue( dev_comms_ext.loc_code ) if ( pos_type == nil or pos_type == '' ) then lua.Error( strLuaDEID, debug.getinfo(1), "设备通讯项'"..comm_code.."'的设置不完整，需要设置该通讯项对应线体处所位置的出入口类型!") end if ( str_loc_code == nil or str_loc_code == '' ) then lua.Error( strLuaDEID, debug.getinfo(1), "设备通讯项'"..comm_code.."'的设置不完整，需要设置该通讯项对应线体所处的货位编码!") end -- step8: 光电有框处理，根据线体所属的出入口类型确定作业类型（入库还是出库） if ( pos_type == '入库线入口' ) then -- 创建入库作业 create_warehousing_operation( strLuaDEID, device_code, str_loc_code, cntr_code ) elseif ( pos_type == '出库线入口' ) then -- 创建出库作业（暂时不需要） elseif ( pos_type == '出库线出口' ) then -- 创建出库作业（暂时不需要） -- 根据托盘号获取任务编号 （完整的任务号无法保存到设备里） local task = XX_GetTaskByCNTR( strLuaDEID, device_code, cntr_code ) if ( task ~= nil ) then -- 设置动作码和动作名称 local action_code = wms_base.Get_nConst(strLuaDEID , "输送线-出库口到货") -- 11 local action = "输送线-出库口到货" -- 把线体编码 line_seg_code 作为data保存到 设备队列 Create_MQAction( strLuaDEID, device_code, task.code, action_code, action, line_seg_code ) else lua.Error( strLuaDEID, debug.getinfo(1), "无法获取任务号! device_code = "..device_code.." cntr_code = "..cntr_code ) end elseif ( pos_type == '入库线出口' ) then -- 新增设备动作队列 -- 根据托盘号获取任务编号 （完整的任务号无法保存到设备里） local task = XX_GetTaskByCNTR( strLuaDEID, device_code, cntr_code ) if ( task ~= nil ) then -- 设置动作码和动作名称 local action_code = wms_base.Get_nConst(strLuaDEID , "输送线-入库口到货") -- 10 local action = "输送线-入库口到货" -- 把线体编码 line_seg_code 作为data保存到 设备队列 Create_MQAction( strLuaDEID, device_code, task.code, action_code, action, line_seg_code ) else lua.Error( strLuaDEID, debug.getinfo(1), "无法获取任务号! device_code = "..device_code.." cntr_code = "..cntr_code ) end else lua.Error( strLuaDEID, debug.getinfo(1), "设备通讯项'"..comm_code.."'的出入口类型设置不正确!") end end